from dependencies.myRabbitmq.amqpUtil import AMQPUtil


class RabbitConsumer(AMQPUtil):

    def __init__(self):
        super(RabbitConsumer, self).__init__()

    @classmethod
    def run(cls, queue, callback):
        consumer = cls()
        consumer.start_consume(callback, queue)
